package com.xkh.rocketmq.config;

import java.util.ArrayList;
import java.util.Arrays;
import java.util.List;

/**
 * @author xkh
 * 2020/10/14
 * RocketMQ服务器配置
 */
public class JmsConfig {
    /**
     * Name Sever 地址，多个用;号隔开
     */
    public static final String NAME_SERVER = "127.0.0.1:9876";
    /**
     * 主题名称
     */
    public static final String TOPIC = "topic_family";
    /**
     * 生产者组
     */
    public static final String PRODUCER_GROUP_NAME= "test_producer";
    /**
     * 消费者组
     */
    public static final String CONSUMER_GROUP_NAME = "test_consumer";

    /**
     * 订阅指定topic下tagA消息
     */
    public static List<String> subscribe = Arrays.asList("Topic-1:test1","Topic-2:test2","Topic-3:test3");




}
